package ken.spring.cloud.alibaba;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.cloud.stream.messaging.Source;
import org.springframework.context.annotation.Bean;

/**
 * <ul>
 * <li>Title: RocketMQApplication</li>
 * <li>Description: TODO </li>
 * </ul>
 *
 * @author swc
 * @date 2022-07-06 15:20
 */
/*@SpringBootApplication
@EnableBinding({ Source.class, Sink.class })
public class RocketMQDemoApplication01 {
    public static void main(String[] args) {
        SpringApplication.run(RocketMQDemoApplication01.class, args);
    }

    //使用方式可以@Bean  也可以使用@Component
    @Bean
    public ProducerRunner customRunner() {
        return new ProducerRunner();
    }
}*/
